package com.yps.io.aio.client;

import java.util.Scanner;

public class Client {

	private static String DEFAULT_HOST = "127.0.0.1";
	private static int DEFAULT_PORT = 12345;
	private static AsyncClientHandler clientHandle;
	public static void start(){
		start(DEFAULT_HOST,DEFAULT_PORT);
	}
	public static synchronized void start(String host, int port){
		if(clientHandle != null){
			return;
		}
		clientHandle = new AsyncClientHandler(host, port);
		new Thread(clientHandle, "Client").start();
	}
	//向服务器发送消息
	public static boolean sendMsg(String msg) throws Exception{
		if(msg.equals("q")){
			return false;
		}
		clientHandle.sendMsg(msg);
		return true;
	}
	public static void main(String[] args) throws Exception {
		//运行客户端   
        Client.start();  
        System.out.println("请输入请求消息：");  
        Scanner scanner = new Scanner(System.in);  
        while(true){  
        	System.out.println(Client.sendMsg(scanner.nextLine()));
        }
	}
}
